什麼是 Celery?
Celery 是一個 Python 庫,用於處理異步任務。它允許你將耗時的任務移出主要應用程式進程,以提高性能和可擴展性。Celery 提供了一個簡單而強大的方式來定義、調度和執行異步任務,這些任務可以是任何 Python 函數。
步驟 1:安裝 Celery
首先,我們需要安裝 Celery 和相關的套件。確保你的 Python 環境已經設置好。
你可以使用 pip 安裝 Celery:
pip install celery
步驟 2:創建一個 Celery 專案
接下來,我們將創建一個簡單的 Celery 專案。首先,在你的專案目錄中創建一個名為 celery_example.py 的 Python 檔案。
celery_example.py
from celery import Celery
建立 Celery 實例
app = Celery('celery_example', broker='pyamqp://guest@localhost//')
定義一個簡單的 Celery 任務
@app.task
def add(x, y):
return x + y
在這個示例中,我們建立了一個 Celery 實例 app,並定義了一個名為 add 的 Celery 任務,該任務接受兩個參數並返回它們的總和。
步驟 3:執行 Celery 任務
現在,你已經安裝了 Celery,並創建了一個簡單的 Celery 專案。接下來,我們將學習如何執行這個 Celery 任務。
首先,啟動 Celery worker。在專案目錄中執行以下命令:
celery -A celery_example worker --loglevel=info
這會啟動一個 Celery worker,等待接受任務。
現在,你可以在 Python 中使用 Celery 來執行你的任務:
from celery_example import add
result = add.delay(4, 6)
print(result.get())
這個代碼將 4 和 6 傳遞給 add 任務,並獲得結果。你應該看到 10 被打印出來,這是 add 任務的返回值。
這就是入門 Celery 的第一步!在下一篇文章中,我們將更深入地探討如何定義和調度不同類型的 Celery 任務。